package prv.liuyao.proxy.queue;

import java.util.function.BiConsumer;

public interface ProxyBiMQ<T, U> {

    void push(T t, U u);

    public ProxyBiMQ<T, U> registryConsumer(BiConsumer<T, U> consumer);

    public void start();

    public void shutdown();

}
